package cn.dglydrpy.study.common.kafka;

import com.alibaba.fastjson.JSON;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.stereotype.Component;

/**
 * 生产者
 */
@Component
@Slf4j
public class KafkaProduer {

    @Autowired
    private KafkaTemplate kafkaTemplate;

    public void send() {
        // 1.定义消息
        KafkaMessage message = new KafkaMessage();
        // 2.set属性值
        // 3.序列化并发送
//        log.info("发送消息 ----->>>>>  message = {}", JSON.toJSON(message));
        this.kafkaTemplate.send("myTopic", JSON.toJSON(message));
    }
}
